collectAsyncFlow

fun <T> Task<CommonFlow<T>>.collectAsyncFlow(    stream: (T) -> Unit,     error: (ClientException) -> Unit,     scope: CoroutineScope = ContextScope.get(DispatchersProvider.Default)): CommonFlow.Job